package com.my.myTradeData;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.nio.charset.Charset;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;

import org.zeromq.ZMQ;
import org.zeromq.ZMQ.Context;
import org.zeromq.ZMQ.Poller;
import org.zeromq.ZMQ.Socket;

public class CopyOfTest {

	public static void main(String[] args) throws IOException, ParseException {
		ZMQ.Context context = ZMQ.context(1);
		ZMQ.Socket s = context.socket(ZMQ.SUB);
		s.connect("tcp://127.0.0.1:5556");
		s.subscribe("".getBytes());

		// tickQueue.offer(d);
		while (true) {

			byte recStr[] = s.recv();
			System.out.println(new String(recStr));
		}
		// TODO Auto-generated method stub
		// App.readTickFile();
//		 ZMQ.Context context = ZMQ.context(1);
//		 ZMQ.Socket s = context.socket(ZMQ.REQ);
//		 s.connect("tcp://*:5671");
//
//		 s.send("buy,ss1,12\0".getBytes());
//		 String rev = new String(s.recv(0));
//		 System.out.println(rev);
//		 File[] files=FileUtil.readFile("D:/xd");
//			for(int i=0;i<files.length;i++){
//				BufferedReader reader = null;
//				try {
//					String tempString="";
//					reader = new BufferedReader(new FileReader(files[i]));
//					while ((tempString = reader.readLine()) != null) {
//						 s.send(tempString.getBytes(), 0);
//						 String rev = new String(s.recv(0));
//						 System.out.println(rev);
//					}
//				} catch (IOException e) {
//					e.printStackTrace();
//				}
//			}
		 
		 

//		ZMQ.Context context = ZMQ.context(1);
//		ZMQ.Socket s = context.socket(ZMQ.REP);
//		s.bind("tcp://*:5672");
//		while (true) {
//			byte[] request = s.recv(); // 获取request发送过来的数据
//			System.out.println("receive : " + new String(request));
//			String response = "world";
//			s.send(response.getBytes());
//		}
		
		
//		Context context = ZMQ.context(1);
//
//		Socket frontend = context.socket(ZMQ.DEALER);
//		frontend.bind("tcp://*:5672");
//
//		Poller items = new Poller (2);
//		items.register(frontend, Poller.POLLIN);
//
//		boolean more = false;
//		byte[] message;
//
//		//  Switch messages between sockets
//		while (!Thread.currentThread().isInterrupted()) {			
//			//  poll and memorize multipart detection
//			items.poll();
//
//			if (items.pollin(0)) {
//				while (true) {
//					// receive message
//					message = frontend.recv(0);
//					more = frontend.hasReceiveMore();
//
//					String str_msg="";
//					if (message != null) {
//						str_msg= new String(message, Charset.forName("UTF-8"));
//					}
//					System.out.print(str_msg);
//					if(!more){
//						break;
//					}
//				}
//			}
//		}
//		//  We never get here but clean up anyhow
//		frontend.close();
//		context.term();
	}

}
